package com.coderman.basketball.infrast.mq;

import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;

/**
 * Description: mq消息处理接口
 * date: 2021/5/25
 *
 * @author shenshuai
 * @version 1.0.0
 * @since JDK 1.8
 */
public interface MqConsumeHandler {
    /**
     * 消息处理入口
     * @param mqBody
     * @return
     */
    void consumeMq(String mqBody);
}
